package com.example.bootdemo.config;

//@Component
public class Producer1 {
//
//    @Autowired
//    private RocketMQTemplate rocketMQTemplate;
//
//    // 发送消息的实例
//    public void sendMessage(String topic, String msg) {
//        rocketMQTemplate.convertAndSend(topic, msg);
//    }
//
//    // 发送事务消息的实例
//    public void sendMessageInTransaction(String topic, String msg) throws InterruptedException {
//        String[] tags = {"TagA", "TagB", "TagC", "TagD", "TagE"};
//        for (int i = 0; i < 10; i++) {
//            Message<String> message = MessageBuilder.withPayload(msg).build();
//            String destination = topic + ":" + tags[i % tags.length];
//
//            TransactionSendResult sendResult =
//                    rocketMQTemplate.sendMessageInTransaction(destination, message, destination);
//
//            System.out.printf("%s%n", sendResult);
//            Thread.sleep(10);
//        }
//    }
}
